package cc.autoapi.pucong.auto.flow.core.flow.execNode.streamBus;

/**
 * 订阅者
 */
public interface IStreamSubscriber {
    void update(String message);

    void emitter(IStreamServiceEmitter IStreamServiceEmitter, IStreamServiceComplate iStreamServiceComplate);

    void runComplete();
}